226c8dc83e215e80ffcb4c879b4871af43a36b92,fabric/fabric-zookeeper/src/main/java/org/apache/curator/framework/recipes/cache/TreeCache.java,TreeCache,getDataAndStat,#String#,541
Before Change
}
};
BackgroundCallback getDataCallback = new BackgroundCallback()
{
@Override
public void processResult(CuratorFramework client, CuratorEvent event) throws Exception
{
applyNewData(fullPath, event.getResultCode(), event.getStat(), event.getData(), children);
}
};
if ( cacheData )
{
if ( dataIsCompressed )
{
client.getData().decompressed().usingWatcher(watcher).inBackground(getDataCallback).forPath(fullPath);
}
else
{
client.getData().usingWatcher(watcher).inBackground(getDataCallback).forPath(fullPath);
}
}
else
After Change
final List<String> children = client.getChildren().usingWatcher(watcher).forPath(fullPath);
if ( cacheData )
{
Stat stat = new Stat();
byte[] data = null;
if ( dataIsCompressed )
{
data = client.getData().decompressed().storingStatIn(stat).usingWatcher(watcher).forPath(fullPath);
}
else
{
data = client.getData().storingStatIn(stat).usingWatcher(watcher).forPath(fullPath);
}
applyNewData(fullPath, KeeperException.Code.OK.intValue(), stat, data, children);
}